var mysql = require('mysql')


// 1. 创建连接
var connection = mysql.createConnection({
    host: 'localhost',
    user: 'user',
    password: '123456',
    database: 'expressdb' // 对不起，我一不小心把数据库名字和表名起成一样的，你知道就行
});


// 2. 连接数据库 打开冰箱门
connection.connect();


// 3. 执行数据操作 把大象放到冰箱
function select(sql, callback) {
    connection.query(sql, function (err, data) {
        if (err) {
            throw err
        }
        callback(null, JSON.parse(JSON.stringify(data)))
    });
}


//插入数据
function insertData(sql, param, callback) {
    connection.query(sql, param, function (error) {
        if (error) {
            throw error
        }
        callback(null)

    });
}
//查询单条数据
function selectById(sql, callback) {
    connection.query(sql, function (error, data) {
        if (error) {
            throw error
        }
        callback(null, JSON.parse(JSON.stringify(data)))

    });
}


//更新数据
function updateData(sql, param, callback) {
    connection.query(sql, param, function (error) {
        if (error) {
            throw error
        }
        callback(null)

    });
}
//删除单条数据
function deleteById(sql, callback) {
    connection.query(sql, function (error) {
        if (error) {
            throw error
        }
        callback(null)

    });
}


// 4. 关闭连接 关闭冰箱门
// connection.end();
module.exports = {
    connection,
    select,
    insertData,
    selectById,
    updateData,
    deleteById
}